package com.yanxu;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @author 折戟沉沙铁未销
 * @version V1.0
 * @date 2025-07-13-2025
 * @Description: api 学习
 */
public class Api01_Env {
    public static void main(String[] args) throws Exception {
        //获取执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        //设置运行模式-- 批处理模式
        //env.setRuntimeMode(RuntimeExecutionMode.BATCH);

        //设置运行模式-- 流处理模式。（默认的运行模式就是 流处理模式）
        //env.setRuntimeMode(RuntimeExecutionMode.STREAMING);

        //对环境进行执行。
        env.execute();
    }
}